package com.zq.im.room.service;

import com.zq.im.room.dao.MessageDao;
import com.zq.im.room.entity.Message;

import java.util.List;

import io.reactivex.Flowable;
import io.reactivex.Single;

/**
 * Created by 张强 869518570@qq.com on 2020/9/22
 */
public class MessageService {

    private MessageDao mMessageDao;

    public MessageService(MessageDao messageDao) {
        mMessageDao = messageDao;
    }

    public Flowable<List<Message>> getMessages(String sendUserId, String acceptUserId){
        return mMessageDao.getMessage(sendUserId, acceptUserId);
    }




}
